package com.example.common.streams;

import org.springframework.cloud.stream.annotation.Output;
import org.springframework.messaging.MessageChannel;

public interface KafkaStreams {

	String TEST_TOPIC_OUTPUT = "test0811";

	@Output(TEST_TOPIC_OUTPUT)
	MessageChannel outboundLogStreams();

}
